package com.holly.unit.kafka.exception;

import com.holly.unit.core.exception.AbstractExceptionEnum;
import com.holly.unit.core.exception.base.ServiceException;
import com.holly.unit.kafka.constants.KafkaConstants;

/**
 * kafka发送消息报错
 * @author pengpeng
 *
 */
public class KafkaException extends ServiceException {

	private static final long serialVersionUID = 1L;

	public KafkaException(String errorCode, String userTip) {
		super(KafkaConstants.KAFKA_MODULE_NAME, errorCode, userTip);
	}

	public KafkaException(AbstractExceptionEnum exceptionEnum, String userTip) {
		super(KafkaConstants.KAFKA_MODULE_NAME, exceptionEnum.getErrorCode(), userTip);
	}

	public KafkaException(AbstractExceptionEnum exceptionEnum) {
		super(KafkaConstants.KAFKA_MODULE_NAME, exceptionEnum);
	}
}
